from KafkaHelper import KafkaHelper

helper = KafkaHelper()
helper.subscribe()
